package org.eking.bigdata.hadoop;

import org.apache.hadoop.mapreduce.Partitioner;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;


public class TestPartition extends Partitioner<Text, IntWritable> {

	@Override
	public int getPartition(Text Key, IntWritable value, int numPartitions) {
		// 
		String StrKey = Key.toString();
		return StrKey.length();
		
	}

}
